package com.example.reactor.reactor;

interface Subscriber<T> {
    void onNext(T value);

    void onComplete();

    void onError(Throwable t);
}
